from kafka import KafkaConsumer

bootstrap_servers = ["x10.111.153.97:9092", "10.111.153.96:9092", "10.111.153.98:9092"]
topic = 'test-med-panel-todo'
group_id = 'test_consumer_wuqifei_all'

consumer = KafkaConsumer(topic,group_id=group_id,bootstrap_servers=bootstrap_servers)

for msg in consumer:
    print(msg.topic,msg.partition,msg.offset)
